package com.cjfather.redis.steam.annotation.constants;
/**
 * 
 * @author: todd
 * @date:   2023-08-08
 */

public interface RedisConstants {

	public static final String STREAM_KEY = "cjfather:stream:msg1";

	public static final String STREAM_GROUP = "cjfather:stream:msg1:group";

	public static final String CONSUMER_NAME = "cjfather:stream:msg1:consumer";

	public static final String QUEUE_MSG = "cjfather:list:msg";
	
	public static final int POLL_BATCH_SIZE = 10;
	
	public static final String STREAM_KEY2 = "cjfather:stream:msg2";

	public static final String STREAM_GROUP2 = "cjfather:stream:msg2:group";

	public static final String CONSUMER_NAME2 = "cjfather:stream:msg2:consumer";
	
	public static final String STREAM_KEY3 = "cjfather:stream:msg3";

	public static final String STREAM_GROUP3 = "cjfather:stream:msg3:group";

	public static final String CONSUMER_NAME3 = "cjfather:stream:msg3:consumer";
	
	public static final String FIRE_STREAM_KEY = "cjfather:warnqueue:fire";

	public static final String FIRE_STREAM_GROUP = "cjfather:warnqueue:fire:group";

	public static final String FIRE_CONSUMER_NAME = "cjfather:warnqueue:fire:consumer";
	
	public static final String FURY_STREAM_KEY = "cjfather:warnqueue:fury";
	
	public static final String NS_STREAM_KEY = "cjfather:warnqueue:ns";
	
	
	/**
	 * datahandling
	 */
	public static final String DATAHANDING2CK = "DataHanding2Ck";
	public static final String DATAHANDING2CK_G = "#{groupTag?.concat('DataHanding2Ck')}";
	
	public static final String OPERATELOG2CK = "OperateLog2Ck";
	public static final String OPERATELOG2CK_G = "OperateLog2Ck";
}
